package com.ehotting.mqbd.zw.client.mqAction;

import com.ehotting.eaf.netty.action.Action;
import com.ehotting.eaf.netty.domain.DataAble;
import com.ehotting.mqbd.zw.api.constants.ActionConstants;
import com.ehotting.mqbd.zw.api.domain.netty.ClusterInfoQueryReq;
import com.ehotting.mqbd.zw.client.mq.ZwMqActionAble;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@Action(value = ActionConstants.Cmd_ClusterInfoQueryStr,isNotice = true)
public class ZwMqClusterInfoQueryAction implements ZwMqActionAble<ClusterInfoQueryReq> {

    @Override
    public DataAble invoke( ClusterInfoQueryReq request) {
        log.info("receive ClusterInfoQueryAction");
        //request.convertToProp();
//        log.info("request:{}", JSON.toJSONString(request));
//        log.info("request.getZwNodeResList().getNodeResList():{}",request.getZwNodeResList().getNodeResList());
        return null;
    }

    @Override
    public Class<?> getRequestClass() {
        return ClusterInfoQueryReq.class;
    }
}
